package com.chj;

import com.chj.utils.PulsarUtil;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Consumer02Application {
    public static  void main(String[] args){
        SpringApplication.run(Consumer02Application.class, args);
//        PulsarUtil.getInstance().subscribe();
        PulsarUtil.getInstance().broadcast();
    }
}
